# -*- coding: UTF-8 -*-

broker_url = 'redis://localhost:6379/1'
result_backend = 'redis://localhost:6379/0'

task_serializer = 'json'
result_serializer = 'json'
accept_content = ['json']
timezone = 'Europe/Oslo'
enable_utc = True

imports = (
    "parse.bean_parse_tasks",
    "handle.handle_tasks",
)

# fixme 需要单独开启每个队列，可能需要一个脚本
task_routes = {
    "parse.bean_parse_tasks.*": {
        "queue": "parse",
    },
    "handle.handle_tasks.*": {
        "queue": "handle"
    },
}